package mapReduce.demo04_IOFormat.inputFormat;

import mapReduce.util.JobSubmit;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat;

import java.io.IOException;

public class SequenceFileInputFormatApp {

    public static class SFIFMapper extends Mapper<Text, IntWritable,Text,IntWritable>{
        @Override
        protected void map(Text key, IntWritable value, Mapper<Text, IntWritable, Text, IntWritable>.Context context) throws IOException, InterruptedException {
            context.write(key, value);
        }
    }

    public static void main(String[] args) {
        JobSubmit.submitBaseJob(SequenceFileInputFormatApp.class,args,0, SequenceFileInputFormat.class);
    }
}
